package message.mq.consumer;

import lodsve.amqp.core.AmqpErrorHandler;
import org.springframework.stereotype.Component;

/**
 * .
 *
 * @author <a href="mailto:sunhao.java@gmail.com">sunhao(sunhao.java@gmail.com)</a>
 * @date 2018-08-06 00:59
 */
@Component
public class TestAmqpErrorHandler extends AmqpErrorHandler {
    @Override
    public void handleError(Throwable t) {
        System.out.println("=====================发生了异常，哈哈哈哈/n/n/n" + t.getMessage());
    }
}
